package com.gdlt.mq2db;

import java.util.List;

import org.apache.kafka.clients.consumer.ConsumerRecord;

public interface Writable  {

	/**
	 * write data and offset
	 * 
	 * @param data
	 * @param offset
	 */

	void write(List<ConsumerRecord<String, String>> data,long offset) ;

	boolean isClosed();

	void close();

}